const mysql = require('mysql');

var pool  = mysql.createPool({
    host     : 'localhost',
    user     : 'root',
    password : 'root',
    port: 3306,
    database: 'test',
    // 是否存在多个连接池
    multipleStatements: true
});

// 一、回调写法
/* function query(sql,cb){
    pool.query(sql,(err,result,fields)=>{
        if(err) throw err
        cb(result);
    })
} */

// 二、async/await(推荐写法)
function query(sql){
    return new Promise((resolve,reject)=>{
        pool.query(sql,(err,result,fields)=>{
            if(err){
                reject(err)
            }
            resolve(result)
        })
    })
}

module.exports = query;